fa0a0f5f0f49324dbc5c0071c0143ce5cf0a235d,src/frontend/org/voltdb/rejoin/StreamSnapshotDataTarget.java,StreamSnapshotDataTarget,close,#,163
Before Change
* could be called multiple times, because all tables share one stream
* target
*/
if (m_mb != null) {
closeIO();
/*
* only join the out thread, once the socket is closed, the in
* thread will terminate
*/
m_outThread.join();
VoltDB.instance().getHostMessenger().removeMailbox(m_mb.getHSId());
m_mb = null;
}
After Change
m_bytesSent.addAndGet(compressedBytes.length);
// release the mailbox and close the socket
VoltDB.instance().getHostMessenger().removeMailbox(m_mb.getHSId());
m_mb = null;
m_closed = true;